package com.bjsxt.disruptor;

import com.lmax.disruptor.ExceptionHandler;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class DisruptorHandlerException implements ExceptionHandler {
    @Override
    public void handleEventException(Throwable ex, long l, Object o) {
        log.info("handleEventException Exception-- {}, sequence-- {} , event--{}",ex.getMessage(),l,o);
    }

    @Override
    public void handleOnStartException(Throwable ex) {
        log.info("OnStartHandle Exception--{}",ex.getMessage());
    }

    @Override
    public void handleOnShutdownException(Throwable ex) {
        log.info("handleOnShutdownException Exception--{}",ex.getMessage());
    }
}
